package com.ywps.vaas.demoTask.dao

import com.ywps.vaas.framework.dao.TDao
import com.ywps.vaas.framework.util.EnvUtil
import org.apache.spark.sql.{DataFrame, SparkSession}

/**
 * demo示例持久层
 */
class SparkSqlDao extends TDao {

  def demo(): Unit = {
    val spark: SparkSession = EnvUtil.take()
    val dataFrame: DataFrame = spark.sql("select current_date")
    dataFrame.show()
  }
}
